--------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------
--------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------
Node / ReticulumProjects / MeshChatX.git / files / meshchatx / src / frontend / js / registries / wsEventBridge.js
Displaying Raw • Download
meshchatx/src/frontend/js/registries/wsEventBridge.js bce42bcdce0e7d2c6d78228e864a4cd1d974cc82 (bce42bcd) Text, 734 B
T8b949e// SPDX-License-Identifier: 0BSD
Tff7b72import Te6edf3WebSocketConnection Tff7b72from Ta5d6ff"../WebSocketConnection.js"Tb4b4b4;
Tff7b72import Tb4b4b4{ Te6edf3dispatchWsEvent Tb4b4b4} Tff7b72from Ta5d6ff"./wsEventRegistry.js"Tb4b4b4;
Tff7b72let Te6edf3bridgeInstalled Tff7b72= Tff7b72falseTb4b4b4;
Tff7b72export Tff7b72function Te6edf3installWsEventBridgeTb4b4b4(Tb4b4b4) Tb4b4b4{
Tff7b72if Tb4b4b4(Te6edf3bridgeInstalledTb4b4b4) Tb4b4b4{
Tff7b72returnTb4b4b4;
Tb4b4b4}
Te6edf3bridgeInstalled Tff7b72= Tff7b72trueTb4b4b4;
Te6edf3WebSocketConnectionTb4b4b4.Te6edf3onTb4b4b4(Ta5d6ff"message"Tb4b4b4, Tff7b72async Tb4b4b4(Te6edf3messageTb4b4b4) Tb4b4b4=> Tb4b4b4{
Tff7b72try Tb4b4b4{
Tff7b72const Te6edf3json Tff7b72= Tffa657JSONTb4b4b4.Te6edf3parseTb4b4b4(Te6edf3messageTb4b4b4.Te6edf3dataTb4b4b4)Tb4b4b4;
Tff7b72if Tb4b4b4(Te6edf3json Tff7b72&& Tff7b72typeof Te6edf3jsonTb4b4b4.Te6edf3type Tff7b72=== Ta5d6ff"string"Tb4b4b4) Tb4b4b4{
Tff7b72await Te6edf3dispatchWsEventTb4b4b4(Te6edf3jsonTb4b4b4.Te6edf3typeTb4b4b4, Te6edf3jsonTb4b4b4)Tb4b4b4;
Tb4b4b4}
Tb4b4b4} Tff7b72catch Tb4b4b4{
T8b949e// non-json payloads are ignored by the typed router
Tb4b4b4}
Tb4b4b4}Tb4b4b4)Tb4b4b4;
Tb4b4b4}
Tff7b72export Tff7b72function Te6edf3resetWsEventBridgeForTestsTb4b4b4(Tb4b4b4) Tb4b4b4{
Te6edf3bridgeInstalled Tff7b72= Tff7b72falseTb4b4b4;
Tb4b4b4}
──────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────